package com.shujia.sink

import org.apache.hadoop.hbase.client.Put

trait HbaseMapper[IN] extends Serializable{
  //提供给用户构建put的接口
  def getPut(kv: IN): Put
}
